#ifndef __WD_THREAD_POOL_H
#define __WD_THREAD_POOL_H 

#include <func.h>
#include "blockq.h"

#define BIG_FILE 104857600

typedef struct {
    pthread_t* threads; // 保存线程的tid
    int num_threads;    // 线程的数目
    blockq_t* task_queue;
} ThreadPool;

typedef struct train_s{
    int length;
    char data[1024];
}train_t;

ThreadPool* create_thread_pool(int n);
void destroy_thread_pool(ThreadPool* pool);

int operation_puts(int netfd, char* pathname);

#endif

